package com.zswl.bus;

import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

/**
 * Created by Administrator on 2018/6/12 0012.
 */

public class RxUtil {


    public static ObservableTransformer io_main_nolife() {
        return new ObservableTransformer() {
            @Override
            public ObservableSource apply(Observable upstream) {

                return upstream.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());

            }
        };
    }

}
